package com.zhou.util;

import com.google.common.collect.Lists;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.flink.core.io.InputSplit;

import java.io.Serializable;
import java.util.LinkedList;

@NoArgsConstructor
@AllArgsConstructor
@Data
public class RequestInputSplit implements InputSplit, Serializable {

    private static final long serialVersionUID = -6814223533871995515L;
    private int splitNum;


    @Override
    public int getSplitNumber() {
        return splitNum;
    }

    public static void main(String[] args) {
        LinkedList<String> list=new LinkedList(Lists.newArrayList("zhou1","zhou2"));

        System.out.println(list.size());
        System.out.println(list.poll());
        System.out.println(list.poll());
        System.out.println(list.size());


    }

}
